package com.iflytek.jcy.supervise.job.jobHandler;

import com.iflytek.jcy.supervise.job.service.IBatchImportService;
import com.iflytek.jcy.supervise.job.service.IModelMiningService;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 模型数据挖掘数据xxl-job执行器
 *
 * 开发步骤：
 *      1、任务开发：在Spring Bean实例中，开发Job方法；
 *      2、注解配置：为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。
 *      3、执行日志：需要通过 "XxlJobHelper.log" 打印执行日志；
 *      4、任务结果：默认任务结果为 "成功" 状态，不需要主动设置；如有诉求，比如设置任务结果为失败，可以通过 ".XxlJobHelperhandleFail/handleSuccess" 自主设置任务结果；
 *
 * @author dgyu 2022-10-30 21:52:51
 */
@Component
public class ModelDataMiningXxlJob {

    private static Logger logger = LoggerFactory.getLogger(ModelDataMiningXxlJob.class);
    @Autowired
    private IModelMiningService modelMiningService;
    
    @Autowired
    private IBatchImportService iBatchImportService;
    
    public static final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    /**
     * 1、模型数据挖掘执行器（Bean模式）
     */
    @XxlJob("ModelDataMiningJobHandler")
    public void modelDataMiningJobHandler() throws Exception {
        String param = XxlJobHelper.getJobParam();
        logger.info("doDataMinging开始执行taskId:{} 开始时间：{}",param,sdf.format(new Date()).replace("T", ""));
        XxlJobHelper.log("doDataMinging开始执行taskId:{} 开始时间：{}",param,sdf.format(new Date()).replace("T", ""));
        this.modelMiningService.doDataMinging(param,false);
        logger.info("doDataMinging结束执行taskId:{} 结束时间:{}",param,sdf.format(new Date()).replace("T", ""));
        XxlJobHelper.log("doDataMinging结束执行taskId:{} 结束时间:{}",param,sdf.format(new Date()).replace("T", ""));
    }
    
    /**
     * 
     * <br>
     * 适用场景:组织机构和用户数据批量导入执行器	<br>
     * 调用方式:	<br>
     * 业务逻辑说明<br>
     *
     * @throws Exception
     * @autho dgyu
     * @time 2022年12月15日 上午10:53:31
     */
    @XxlJob("BatchImportOrgAndUserJobHandler")
    public void BatchImportOrgAndUserJobHandler() throws Exception {
        String param = XxlJobHelper.getJobParam();
        logger.info("BatchImportOrgAndUserJobHandler开始执行，参数:{} 开始时间：{}",param,sdf.format(new Date()).replace("T", ""));
        XxlJobHelper.log("BatchImportOrgAndUserJobHandler开始执行，参数:{} 开始时间：{}",param,sdf.format(new Date()).replace("T", ""));
        this.iBatchImportService.batchImport();
        logger.info("BatchImportOrgAndUserJobHandler结束执行，参数:{} 结束时间:{}",param,sdf.format(new Date()).replace("T", ""));
        XxlJobHelper.log("BatchImportOrgAndUserJobHandler结束执行，参数:{} 结束时间:{}",param,sdf.format(new Date()).replace("T", ""));
    }
    public void init(){
        logger.info("init");
    }
    public void destroy(){
        logger.info("destroy");
    }


}
